package com.lzq.mq.broker.model;

import lombok.Data;

/**
 * 消费队列拉取消息请求对象
 */
@Data
public class ConsumeQueueConsumeReqModel {

    private String topic;

    /**
     * 消费者组
     */
    private String consumeGroup;

    /**
     * 队列id
     */
    private Integer queueId;

    /**
     * 拉取数量
     */
    private Integer batchSize;

}
